e2dbfe0486bec03a2625cdb9abe237224cf45066,joker-engine/src/test/java/cs/bilkent/joker/engine/tuplequeue/impl/queue/MultiThreadedTupleQueueTest.java,MultiThreadedTupleQueueTest,shouldPollExactNumberOfTuples,#,204
Before Change
public void shouldPollExactNumberOfTuples () throws InterruptedException
{
queue.disableCapacityCheck();
final Thread thread = spawnThread( offerTuples( Thread.currentThread(),
queue,
asList( newTuple( 1 ), newTuple( 2 ), newTuple( 3 ), newTuple( 4 ) ) ) );
final List<Tuple> tuples = queue.pollTuples( 2 );
assertEquals( 2, tuples.size() );
thread.join();
}
@Test
After Change
@Test
public void shouldPollExactNumberOfTuples () throws InterruptedException
{
queue.offerTuples( asList( newTuple( 1 ), newTuple( 2 ), newTuple( 3 ) ) );
final List<Tuple> tuples = queue.pollTuples( 2 );
assertEquals( 2, tuples.size() );